package com.baichen.trade.rocketmq;

import org.apache.rocketmq.common.message.MessageExt;

/**
 * @Date: 2019-11-07 23:37
 * @Author: baichen
 * @Description 处理消息的接口
 */
public interface IMessageProcessor {
    boolean handleMessage(MessageExt messageExt);
}
